﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace LJ.EventBus.Abstractions;

public interface IEventBusPublisher
{
    Task PublishAsync<T>(string name, T value, CancellationToken cancellationToken = default);

    Task PublishAsync<T>(string name, T value, IDictionary<string, string?> headers, CancellationToken cancellationToken = default);
}
